<?php
require_once "Pay.Exception.php";
require_once "Pay.Config.php";
require_once "Pay.Data.php";
require_once 'Pay.Log.php';


/**
 * 
 * 接口访问类，包含所有支付API列表的封装，类中方法为static方法，
 * 接口有默认超时时间
 * @author jiangwentong
 *
 */
class PayApi
{
    /**
     *
     * 统一请求接口
     * @param UnifiedData $inputObj
     * @param string $url 交易地址
     * @param int $timeOut 请求超时
     * @return 成功时返回
     */
	public static function unifiedRequest($inputObj, $url = PayConfig::API_TEST_URL_HTTP ,$timeOut = 15)
	{
		//异步通知url未设置，则使用配置文件中的url
		if(!$inputObj->IsParamSet("notifyUrl") && PayConfig::USE_DEFAULT_NOTIFY){
            //异步通知url
			$inputObj->SetParam("notifyUrl", PayConfig::NOTIFY_URL);
		}
		if(!$inputObj->IsParamSet("agtId")) {
            $inputObj->SetParam("agtId", PayConfig::AGTID);//公众账号ID
        }
        if(!$inputObj->IsParamSet("merId")) {
            $inputObj->SetParam("merId", PayConfig::MERID);//商户号
        }
        if(!$inputObj->IsParamSet("nonceStr")) {
            $inputObj->SetParam("nonceStr", self::getNonceStr());//随机字符串
        }

		//签名
		$inputObj->SetSign();
		
		$json = $inputObj->ToJson();
		
		LOG::DEBUG("请求参数:".$json);

		$startTimeStamp = self::getMillisecond();//请求开始时间
		$response = self::postJsonCurl($json, $url, false, $timeOut);
		$result = PayResults::Init($response);
		return $result;
	}


 	/**
 	 * 
 	 * 支付结果通用通知
 	 * @param function $callback
 	 * 直接回调函数使用方法: notify(you_function);
 	 * 回调类成员函数方法:notify(array($this, you_function));
 	 * $callback  原型为：function function_name($data){}
 	 */
	public static function notify($callback, &$msg)
	{
		//获取通知的数据
		$xml = $GLOBALS['HTTP_RAW_POST_DATA'];
		//如果返回成功则验证签名
		try {
			$result = PayResults::Init($xml);
		} catch (PayException $e){
			$msg = $e->errorMessage();
			return false;
		}
		
		return call_user_func($callback, $result);
	}
	
	/**
	 * 
	 * 产生随机字符串，不长于32位
	 * @param int $length
	 * @return 产生的随机字符串
	 */
	public static function getNonceStr($length = 16)
	{
		$chars = "abcdefghijklmnopqrstuvwxyz0123456789";  
		$str ="";
		for ( $i = 0; $i < $length; $i++ )  {  
			$str .= substr($chars, mt_rand(0, strlen($chars)-1), 1);  
		} 
		return $str;
	}

    /**
     *
     * 产生随机数字字符串
     * @param int $length
     * @return 产生随机数字字符串
     */
    public static function getNonceNumber($length = 4)
    {
        $chars = "0123456789";
        $str ="";
        for ( $i = 0; $i < $length; $i++ )  {
            $str .= substr($chars, mt_rand(0, strlen($chars)-1), 1);
        }
        return $str;
    }
	
	/**
	 * 直接输出json
	 * @param string $json
	 */
	public static function replyNotify($json)
	{
		echo $json;
	}
	
	

	/**
	 * 以post方式提交json到对应的接口url
	 * 
	 * @param string $json  需要post的json数据
	 * @param string $url  url
	 * @param bool $useCert 是否需要证书，默认不需要
	 * @param int $second   url执行超时时间，默认30s
	 * @throws PayException
	 */
	private static function postJsonCurl($json, $url, $useCert = false, $second = 60)
	{	
		LOG::DEBUG("curl请求数据：".$json);
		self::getRuntime(0);
		$ch = curl_init();
		//设置超时
		curl_setopt($ch, CURLOPT_TIMEOUT, $second);
		
		//如果有配置代理这里就设置代理
		if(PayConfig::CURL_PROXY_HOST != "0.0.0.0"
			&& PayConfig::CURL_PROXY_PORT != 0){
			curl_setopt($ch,CURLOPT_PROXY, PayConfig::CURL_PROXY_HOST);
			curl_setopt($ch,CURLOPT_PROXYPORT, PayConfig::CURL_PROXY_PORT);
		}
		curl_setopt($ch,CURLOPT_URL, $url);
		curl_setopt($ch,CURLOPT_SSL_VERIFYPEER,TRUE);
		curl_setopt($ch,CURLOPT_SSL_VERIFYHOST,2);//严格校验
		//设置header
		curl_setopt($ch, CURLOPT_HEADER, FALSE);
		//要求结果为字符串且输出到屏幕上
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
	
		if($useCert == true){
			//设置证书
			//使用证书：cert 与 key 分别属于两个.pem文件
			curl_setopt($ch,CURLOPT_SSLCERTTYPE,'PEM');
			curl_setopt($ch,CURLOPT_SSLCERT, PayConfig::SSLCERT_PATH);
			curl_setopt($ch,CURLOPT_SSLKEYTYPE,'PEM');
			curl_setopt($ch,CURLOPT_SSLKEY, PayConfig::SSLKEY_PATH);
		}
		//post提交方式
		curl_setopt($ch, CURLOPT_POST, TRUE);
		curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
		//运行curl
		$data = curl_exec($ch);
		//返回结果
		LOG::DEBUG("curl返回数据：".$data);
		LOG::DEBUG("curl请求耗时 ：".self::getRuntime(1));
		if($data){
			curl_close($ch);
			return $data;
		} else { 
			$error = curl_errno($ch);
			curl_close($ch);
			LOG::ERROR("curl出错，错误码:$error");
			throw new PayException("curl出错，错误码:$error");
		}
		
	}
	
	/**
	 * 获取毫秒级别的时间戳
	 */
	private static function getMillisecond()
	{
		//获取毫秒的时间戳
		$time = explode ( " ", microtime () );
		$time = $time[1] . ($time[0] * 1000);
		$time2 = explode( ".", $time );
		$time = $time2[0];
		return $time;
	}

	/**
	 * 函数:计时函数
	 * 用法:Echo Runtime(1);
	 * @param unknown_type $mode
	 */
	private static function getRuntime($mode=0){
	    static $s;
	    if(!$mode){
	        $s=microtime();
	        Return;
	    }
	    $e=microtime();
	    $s=explode(" ", $s);
	    $e=explode(" ", $e);
	    return Sprintf("%.2f ms",($e[1]+$e[0]-$s[1]-$s[0])*1000);
	}
}

